bytes_data = BytesIO()
for d in data_source.stream(32 * 1024):
    bytes_data.write(d)
bytes_data.seek(0)
{{df_name}} = pd.{{read_function}}(bytes_data)